package com.choosefine.base.common.model

import org.springframework.jms.core.MessageCreator
import javax.jms.Message
import javax.jms.Session

/**
 * Created by 邱鹏 on 2017/8/30.
 */
open class ActiveMqMessage(val messageStr: String) : MessageCreator {
    override fun createMessage(session: Session?): Message {
        return session!!.createTextMessage(messageStr)//调用session的createTextMessage创建消息
    }

}